package com.camemax.rabbitmq.headers_mode.bindings;

import com.camemax.rabbitmq.utils.BindingsModules;

import java.util.HashMap;
import java.util.Map;

public class HeadersMode_Bindings {
    public static void main(String[] args) {
        Map<String, Object> headersType = new HashMap<>();
        Map<String, Object> headersAuthor = new HashMap<>();
        Map<String, Object> headersTag = new HashMap<>();

        headersType.put("type", "HEADERS");
        headersAuthor.put("author", "CAMEMAX");
        headersTag.put("tag", "RABBITMQ");
        new Thread(new BindingsModules("headers-exchange", "headers-queue01", "headers-rk", headersType)).start();
        new Thread(new BindingsModules("headers-exchange", "headers-queue02", "headers-rk", headersAuthor)).start();
        new Thread(new BindingsModules("headers-exchange", "headers-queue03", "headers-rk", headersTag)).start();
    }
}
